package com.lab.book.web.message;

import org.apache.commons.lang.StringUtils;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import com.lab.book.common.bean.LoginHistory;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Component
public class LoginHistorySender {

	@Value("${rocketmq.topic.loginHistory1}")
	private String loginHistoryTopic;

	@Autowired
	private RocketMQTemplate rocketMQTemplate;

	public void sendLoginHistory(LoginHistory loginHistory) {
		log.info(StringUtils.center("sendLoginHistory", 52, "="));

		// 使用RocketMQ 发送
		SendResult sendResult = rocketMQTemplate.syncSend(loginHistoryTopic, loginHistory);
		log.info("syncSend to topic {} sendResult={} %n", loginHistoryTopic, sendResult);
	}
}